package cn.xiaopengstack.infrastructure.persistent.dao;

import cn.bugstack.middleware.db.router.annotation.DBRouter;
import cn.xiaopengstack.infrastructure.persistent.po.Task;
import org.apache.ibatis.annotations.Mapper;

import java.util.List;

/**
* @author jiangyangang
* @description 针对表【task(任务表，发送MQ)】的数据库操作Mapper
* @createDate 2025-07-02 11:45:37
* @Entity cn.xiaopengstack.infrastructure.persistent.po.Task
*/
@Mapper
public interface ITaskDao {


    @DBRouter
    int insertSelective(Task record);

    Task selectByPrimaryKey(Long id);

    int updateByPrimaryKeySelective(Task record);

    int updateByPrimaryKey(Task record);

    @DBRouter
    void updateTaskSendMessageCompleted(Task task);

    @DBRouter
    void updateTaskSendMessageFail(Task task);

    List<Task> queryNoSendMessageTaskList();
}
